package cn.edu.flink.scala.tutorial.source

import org.apache.flink.streaming.api.functions.source.SourceFunction
import org.apache.flink.streaming.api.scala._
import scala.util.Random

object AddSourceTest {
  def main(args: Array[String]): Unit = {
    val env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI()
    env.setParallelism(1)

    val eventDS = env.addSource(new ClickSource())

    eventDS.print("eventDS")

    env.execute("AddSource")
  }
}


